package com.fxd.rocketmq.core;

import org.apache.rocketmq.common.message.MessageExt;
import org.springframework.context.ApplicationEvent;

/**
 * @author xudongfu
 * @date 2023/02/27
 */
public class RocketMqEvent extends ApplicationEvent {

    private MessageExt msg;

    public RocketMqEvent(MessageExt msg) {
        super(msg);
        this.msg = msg;
    }

    public MessageExt getMsg() {
        return msg;
    }
}
